// 创建一个SparkSession实例
// 并读取sales_data.csv文件到DataFrame中
// 检查并展示DataFrame的前5行数据

import org.apache.spark.sql.SparkSession
val spark = SparkSession.builderappName("SalesDataExperiment").getOrCreate()

import spark.implicits._

val salesDF = spark.readformat("csv")
            .option("header", "true")
            .option("inferSchema", "true")
            .load("sales_data.csv")

salesDF.printSchema()

salesDF.show(5)